//package com.haruhi.ws.server;
//
//import com.haruhi.event.Message;
//import com.haruhi.event.MessageQueue;
//import com.haruhi.event.MessageSource;
//import com.haruhi.ws.WsListener;
//import javax.websocket.CloseReason;
//
//import javax.websocket.EndpointConfig;
//
//
//import javax.websocket.Session;
//
//public class ServerEndpoint implements WsListener {
//
//    private final Integer port;
//
//    public ServerEndpoint(int port){
//        this.port = port;
//    }
//
//    @Override
//    public void onClose(Session session, CloseReason closeReason) {
//    }
//
//    @Override
//    public void onMessage(Session session, String msg) {
//        // 这里的消息都是从远程客户端传来的 所以source是CLIENT
//        MessageQueue.offer(new Message(session,msg, MessageSource.CLIENT));
//    }
//
//    @Override
//    public void onError(Session session, Throwable thr) {
//    }
//
//    @Override
//    public void onOpen(Session session, EndpointConfig endpointConfig) {
//    }
//
//}
